-
Notifications
You must be signed in to change notification settings - Fork 534
1.0.2-RC1: Fix the IdentityFlowProcessorVerification class #419
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
1.0.2-RC1: Fix the IdentityFlowProcessorVerification class #419
Conversation
Thanks for finding, and fixing, this issue, David! @reactive-streams/contributors Merge? |
* The expected behaviour of the {@link Flow.Publisher} returned by this method is hand out a subscription, | ||
* followed by signalling {@code onError} on it, as specified by Rule 1.9. | ||
* | ||
* If you ignore these additional tests, return {@code null} from this method. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If you want to ignore these additional...
@@ -128,7 +128,7 @@ public boolean skipStochasticTests() { | |||
|
|||
/** | |||
* This is the main method you must implement in your test incarnation. | |||
* It must create a Publisher, which simply forwards all stream elements from its upstream | |||
* It must create a {@link Processor}, which simply forwards all stream elements from its upstream |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, thanks for spotting it!
Awesome, @akarnokd! @reactive-streams/contributors Merging |
This PR fixes the
IdentityFlowProcessorVerification
class as it did not properly use theFlowAdapters
and required the developer to specify helper structures manually and unnecessarily.The
LockstepFlowProcessorTest
was ported as a nativeFlow.Processor
implementation to ensureIdentityFlowProcessorVerification
is properly implementable.Related: #413 (comment)